package com.loveprogrammer.redismq.annotation;

import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;

@Retention(RetentionPolicy.RUNTIME)
public @interface Listeners {

    /**
     * 转换为DefaultMqPushConsumer后订阅的topic
     * 默认为“DEFAULT_TOPIC”
     */
    String topic() default "DEFAULT_TOPIC";
}
